package com.bdi.mqtt_broker.config;

import io.netty.channel.group.ChannelGroup;
import io.netty.channel.group.DefaultChannelGroup;
import io.netty.util.concurrent.GlobalEventExecutor;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * @author WangNing yogehaoren@gmial.com <br>
 * @since 1.0
 * Broker配置文件
 */

@Configuration
public class BrokerContextConfig {


    @Bean
    public ChannelGroup channelGroup(){
        return new DefaultChannelGroup(GlobalEventExecutor.INSTANCE);
    }

}
